import java.util.concurrent.BlockingDeque;
import java.util.concurrent.LinkedBlockingDeque;

public class Demo29 {
    //使用阻塞队例(消息队列)：设置该队列的最大容量；
    //向该队列中添加元素，直到添加元素满了即可；
    //接着在进行添加元素，观察该消息队列是否会进行阻塞；
    //观察执行结果，就可以体会消息队列的执行情况；
    public static void main(String[] args) throws InterruptedException {
        BlockingDeque<String> blockingDeque=new LinkedBlockingDeque<>(100);
         String n="aaa";
        System.out.println("向队列中添加元素,直到添加满了即可");
        for(int i=0;i<100;i++){
            blockingDeque.put(n);
        }
        System.out.println("消息队列已经放满了，不能在进行添加");
        //blockingDeque.put(n);
        System.out.println("再次尝试向队列中添加元素");

    }

}
